Building Stream Processing Pipelines With Dataflow